package com.kc.demo.kcapidemo.web;

import com.alibaba.fastjson.JSONObject;
import com.kc.demo.kcapidemo.mqtt.MqttRunServer;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.UUID;

/**
 * @version v1.0
 * @类描述：
 * @项目名称：
 * @包名： com.kc.demo.kcapidemo.web
 * @类名称：TestWebSocket
 * @创建人：YIHANG.XU
 * @创建时间：2021/10/25:07 下午
 * @修改人：YIHANG.XU
 * @修改时间：2021/10/25:07 下午
 * @修改备注：
 * @Copyright
 */
@RestController
@RequestMapping("/mqttDemo")
public class TestWebMqtt {
    @RequestMapping("/demo")
    public void pushMs() throws MqttException {
        String replace = UUID.randomUUID().toString().replace("-", "");
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("强强", "是大懒蛋");
        jsonObject.put("ceshi", "1112");
        jsonObject.put("id", replace);
        String string = jsonObject.toJSONString();
        MqttRunServer.pustMesssge(string);
    }

}
